package com.neusoft.neu24.nep.controller;

import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.alibaba.csp.sentinel.slots.block.BlockException;
import com.neusoft.neu24.nep.entity.CommonResult;
import com.neusoft.neu24.nep.entity.HttpCodeEnum;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.concurrent.TimeUnit;

@RestController
@CrossOrigin("*")
@RequestMapping("/s")
public class TestController {
    static  int index = 0 ;
    @RequestMapping("/t")
    /**
     * blockHandler / blockHandlerClass: blockHandler 对应处理 BlockException 的函数名称，
     * 可选项。blockHandler 函数访问范围需要是 public，返回类型需要与原方法相匹配，
     * 参数类型需要和原方法相匹配并且最后加一个额外的参数，类型为 BlockException。
     *
     */
    @SentinelResource(value = "test", blockHandler = "blockHandler" ,fallback = "fallback")
//    BlockException
    public CommonResult test() throws InterruptedException {
//        if (index++ % 2 == 0){
//            int  i  =0;
//            int  j =1;
//            j =  j / i ;
//        }
//        TimeUnit.SECONDS.sleep(1);
        return  CommonResult.sucess("通过了Sentinel") ;

        // Fallback 函数，函数签名与原函数一致或加一个 Throwable 类型的参数.
        // 降级响应

    }
//   所有

    /**
     * fallback/fallbackClass：fallback 函数名称，
     * 可选项，用于在抛出异常的时候提供 fallback 处理逻辑。
     * fallback 函数可以针对所有类型的异常（除了exceptionsToIgnore里面排除掉的异常类型）进行处理。
     * @return
     */
    public CommonResult fallback( ) {
        return   new CommonResult( HttpCodeEnum.BLOCK_BY_FlowException) ;

    }

    // Block 异常处理函数，参数最后多一个 BlockException，其余与原函数一致.
    // 异常处理
    public CommonResult blockHandler(  BlockException ex){
        // Do some log here.
        // ex.printStackTrace();
        System.out.println(ex.getMessage());
        return   CommonResult.filure( HttpCodeEnum.BLOCK_BY_FlowException ) ;
    }
}
